public ApplicationSpecification configure() {
return ApplicationSpecification.builder()
.addFlow(CountCounts.class)
.addStream(new Stream("test"))
.create();
}
}
return ApplicationSpecification.builder()
.addFlow(CountCounts.class)
.addQuery(CountQuery.class)
.addStream(new Stream("text"))
.addDataSet(new CounterTable(Common.tableName))
.create();
}
}